def onVirq(self, event, val):
"""Event handler for virq.
"""
- print 'XendDomain> virq', val
self.reap()
def schedule_later(self, _delay, _name, _fn, *args):
def initial_refresh(self):
"""Refresh initial domain info from domain_db.
"""
- for d in self.domain_db.values(): print 'db dom=', d
+ #for d in self.domain_db.values(): print 'db dom=', d
domlist = xc.domain_getinfo()
- for d in domlist: print 'xc dom=', d
+ #for d in domlist: print 'xc dom=', d
doms = {}
for d in domlist:
domid = str(d['dom'])
dlist = []
for config in self.domain_db.values():
domid = str(sxp.child_value(config, 'id'))
- print "dom=", domid, "config=", config
+ #print "dom=", domid, "config=", config
if domid in doms:
- print "dom=", domid, "new"
+ #print "dom=", domid, "new"
deferred = self._new_domain(config, doms[domid])
dlist.append(deferred)
else:
- print "dom=", domid, "del"
+ #print "dom=", domid, "del"
self._delete_domain(domid)
deferred = defer.DeferredList(dlist, fireOnOneErrback=1)
def cbok(val):
#print "doms:"
#for d in self.domain.values(): print 'dom', d
self.refresh()
- print "XendDomain>initial_refresh> doms:"
- for d in self.domain.values(): print 'dom', d
+ #print "XendDomain>initial_refresh> doms:"
+ #for d in self.domain.values(): print 'dom', d
deferred.addCallback(cbok)
def sync(self):
"""Refresh domain list from Xen.
"""
self.refresh_cancel()
- print 'XendDomain>refresh>'
domlist = xc.domain_getinfo()
# Index the domlist by id.
# Add entries for any domains we don't know about.
@param id: domain id
@param reason: shutdown reason
"""
- print 'domain_restart_schedule>', id, reason
dominfo = self.domain.get(id)
if not dominfo or id in self.restarts:
# Don't schedule if unknown or already there.
- print 'domain_restart_schedule> no domain'
return
restart = ((reason == 'reboot') or
(reason == 'poweroff' and dominfo.autorestart))
@param id: domain id
"""
- print 'domain_restart_cancel>', id
dominfo = self.domain.get(id)
if dominfo:
dominfo.autorestart = 0
def domain_restarts(self):
"""Execute any scheduled domain restarts for domains that have gone.
"""
- print 'domain_restarts>'
self.domain_restarts_cancel()
for id in self.restarts.keys():
if id in self.domain:
- print 'domain_restarts> still running:', id
# Don't execute restart for domains still running.
continue
config = self.restarts[id]